//
//
//import rx.Observable;
//import rx.Subscriber;
//
///**
// * @author shengtao
// * @Description:
// * @date 2018/08/24 15:43
// */
//public class test {
//
//    public static void test(){
//        //创建订阅者
//        Subscriber<String> subscriber = new Subscriber<String>() {
//            @Override
//            public void onCompleted() {
//                System.out.println("complate");
//            }
//
//            @Override
//            public void onError(Throwable throwable) {
//                System.out.println("error"+throwable.toString());
//            }
//
//            @Override
//            public void onNext(String s) {
//                System.out.println("observer:"+s);
//            }
//        };
//        //创建事件源
//        Observable<String> observable = Observable.create(new Observable.OnSubscribe<String>() {
//            @Override
//            public void call(Subscriber<? super String> subscriber) {
//                subscriber.onNext("hello rxjava");
//                subscriber.onNext("hello ,我是程序员");
//                subscriber.onCompleted();
//            }
//        });
//        observable.subscribe(subscriber); //建立订阅关系
//
//
//    }
//
//    public static void main(String[] args){
//        test();
//    }
//
//}
